#include "../mqserver/mq_connection.hpp"

/* 
  该模块无法进行单元测试, 因此只进行简单的编译测试
*/
int main()
{
    mqserver::ConnectionManagerPtr conn_mg = std::make_shared<mqserver::ConnectionManager>();
    conn_mg->newConnection(mqserver::ProtobufCodecPtr(), 
        muduo::net::TcpConnectionPtr(), 
        std::make_shared<mqserver::VirtualHost>("host1", "./data/host1/message/", "./data/host1/host1.db"), 
        std::make_shared<mqserver::ConsumerManager>(),
        pool::ThreadPoolPtr());
    
    return 0;
}